package org.mxp.demo2;

import com.rabbitmq.client.Channel;
import org.mxp.utils.RabbitMQUtils;

public class SendObj {
    public static void main(String[] args) throws Exception {
        // 获取信道
        Channel channel = RabbitMQUtils.getChannel();
        // 生成一个队列
        channel.queueDeclare("demo2", false, false, false, null);
        // 定义消息内容
        String message = "hello world ";
        // 发送10条消息
        for (int i = 0; i < 10; i++) {
            channel.basicPublish("", "demo2", null, (message + i).getBytes());
        }
        System.out.println("消息发送完毕");

        // 创建随机队列并返回队列名称
        String queueName = channel.queueDeclare().getQueue();
    }
}
